package com.sumbo.config.writer;

import com.sumbo.config.constant.ClientType;

/**
 * \* User: MeiZhongHao
 * \* Date: 2019-06-10
 * \* Time: 17:08
 * \* Description:  Kafka输出上下文
 * \
 */
public class KafkaOutputContext extends OutputContext {

    private String topic;

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public KafkaOutputContext() {
        this.setType(ClientType.KAFKA);
    }
}